//package com.bs.kafka.controller;
//
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.web.bind.annotation.*;
//
//import javax.annotation.Resource;
//
///**
// * @author bingshao
// * @date 2022/10/9
// **/
//@RestController
//@RequestMapping("/producer")
//public class ProducerController {
//
//    @Resource
//    private KafkaTemplate<String, Object> kafkaTemplate;
//
//    @GetMapping("/send/{msg}")
//    public void sendMessage(@PathVariable("msg") String msg) {
//        kafkaTemplate.send("test1", msg);
//    }
//
//    @GetMapping("/sendFlink/{msg}")
//    public void sendMessageFlinkTest(@PathVariable("msg") String msg) {
//        kafkaTemplate.send("flink-test", msg);
//    }
//
//
//}
